# Copyright (c) 2019 Presto Labs Pte. Ltd.
# Author: donggu

from experimental.prophet.graph import graph


def merge_proto_feeds(proto_feeds, **kwargs):
  assert isinstance(proto_feeds, list)

  # cache = graph.get_aux_entry('proto_feed_merge')
  # key = '%s|%s|%s' % ('0;', str(kwargs))
  # if key not in cache:
  #   with graph.control_if(None):
  #     cache[key] = graph.create_node('fastfeed.ProtoFeedMerge', proto_feeds).outputs.proto

  # return cache[key]

  return graph.create_node('fastfeed.ProtoFeedMerge', proto_feeds).outputs.proto
